package com.kx.push.quartz.scheduler;

import com.kx.push.quartz.job.IdemDelJob;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

/**
 * 创建调度任务
 * @Author Sun
 * @Date 2021/7/30 19:05
 */
public class IdemDataScheduler {

    /**
     * 创建调度器的方法
     */
    public Scheduler getScheduler() throws SchedulerException {
        StdSchedulerFactory stdSchedulerFactory = new StdSchedulerFactory();
        return stdSchedulerFactory.getScheduler();
    }

    /**
     * 定时任务的方法
     */
    public void schedulerJob()throws Exception{
        //创建任务
        JobDetail jobDetail = JobBuilder.newJob(IdemDelJob.class).withIdentity("delIdem", "idem").build();
        //每三分钟执行一次
        String cron ="0 0/3 * * * ?";
        CronTrigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("delItem", "idem")
                .withSchedule(CronScheduleBuilder.cronSchedule(cron))
                .build();

        Scheduler scheduler=getScheduler();

        //调度任务
        scheduler.scheduleJob(jobDetail,trigger);
        //开始任务
        scheduler.start();
    }
}
